package com.flyway.execise.flyway_db.cart;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;

/**
 * @date 19-6-3
 * @auther jackliang
 * @description TODO
 */
public class CommonConstants {

    public static final int RANK = 10;

    public static final int ITERATIONS = 10;

    public static final int BLOCKS = -1;

    public static final double LAMBDA = 0.01;

    public static final String SPARK_MASTER_PATH = "local[*]";

    public static final String LOADER_PATH = "spark.resource.path";

    public static final String QUALIFIED_PACKAGE_PATH = "com.kili.mirco.spark.als";

    public static final String DEPLOY_STATIC_ACTION = "mvn clean compile";

    public static final String USER_DIR = "user.dir";

    public static final String MULTABLE_PROPERTY_VALUE = "applicationConfig: [classpath:/application.properties]";

    public static final String SUBFFIX_PROPERTIES = ".properties";

    public static final String SUBFFIX_JAVA = ".java";

    public static final String OS_NAME = "os.name";

    public static final String LINUX = "linux";

    public static final String PREFIX_EXACUTIO_NAME = "heat.container.exacutio";

    public static void main(String[] args) throws InterruptedException {
        BlockingDeque blockingDeque = new LinkedBlockingDeque<>(10000);
        for (int i = 0; i < 1000; i++) {
            blockingDeque.offer(ThreadLocalRandom.current().nextDouble());
        }

        while (true) {
            System.out.println(blockingDeque.poll(10, TimeUnit.MINUTES));

        }

    }
}
